/**
 * 
 */
package com.scalyze.apps.socialanyltics.auth.api;

import java.io.InputStream;

/**
 * @author vivek.mishra
 * 
 * Authenticator interface.
 *
 */
public interface Collector
{
    
    /**
     * Authenticate the request
     */
    void authenticate(final String params, final String connectionUrl);

    /**
     * Returns input stream
     * @return input stream
     */
    InputStream getStream();
    
    /**
     * Returns response code.
     * @return responseCode.
     */
    int getResponseCode();
    
    /**
     * tweet message
     * @param tweetMsg
     * @param hbaseMasterNode
     * @param hbaseMasterPort
     * @param zookeeperHost
     */
    void collectTweets(String tweet, String hbaseMasterNode,String hbaseMasterPort, String zookeeperHost, String trendName);
}
